package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.arithmetic.common.Cn6BasicDataInfo;
import com.navinfo.tripanalysis.common.pojo.Point;
import org.apache.spark.api.java.JavaPairRDD;

import java.util.List;
import java.util.Map;

/**
 * 给定流的融合服务
 * @author 刘俊
 */
public interface DataCombineService {
    JavaPairRDD<Long, List<Point>> combineByTidAndSortByTime(JavaPairRDD<Long, List<Point>> pointsRdd1, JavaPairRDD<Long, List<Point>> pointsRdd2, Map<Long, Cn6BasicDataInfo> cn6BasicDataInfoMap);
}
